#ifndef SPEAKER_HPP
#define SPEAKER_HPP

#include "workitem.hpp"
#include <coreconfigdefs.hpp>
#include <coredataqueue.hpp>
#include <coredataunit.hpp>
#include <coreconfigdefs.hpp>
#include <pland.hpp>
#include <boost/thread/mutex.hpp>
namespace kport
{

class Speaker : public WorkItem
{
public:
	Speaker(int sock, pland::SharedDQueue qin);
	~Speaker();
	bool ready() throw(pland::Exeption);
	WorkItemStat work() throw(pland::Exeption);
    WorkItem::TYPE type(){return WorkItem::OUT;}
private:
	int sock_;
	pland::SharedDQueue qin_;
};

}
#endif // SPEAKER_HPP
